package com.kevin.demo.springbootdemo2.controller.queue;

import org.springframework.jms.annotation.JmsListener;
import org.springframework.web.bind.annotation.RestController;

/**
 * @author kevin
 * @version： QueueConsumerController.java v 1.0, 2020年05月20日 20:47
 * @Description 消费者
 **/
@RestController
public class QueueConsumerController {

    /**
     * 消费者: 监听 和 消费消息
     *
     * @param msg
     */
    @JmsListener(destination = "active.queue1")
    public void consumerMsg(String msg) {
        System.out.println("msg = " + msg);
    }
}
